package xmq

import "context"

type MQWriter interface {
	MQCloser
	WriteMsg(ctx context.Context, k string, v interface{}) (string, error)
}
type MQCloser interface {
	Close(ctx context.Context) (err error)
}
